package com.ngkj.zmfptback.sys.util;

import com.ngkj.zmfptCommon.common.bean.RpcRequestMessage;
import com.ngkj.zmfptCommon.common.util.SerializeUtil;
import org.apache.kafka.common.serialization.Serializer;

/**
 * @author ChenHN
 * @since 2021/11/15 creation
 **/
public class RpcRequestSeralizer implements Serializer<RpcRequestMessage> {
    @Override
    public byte[] serialize(String s, RpcRequestMessage rpcRequestMessage) {
        return SerializeUtil.serialize(rpcRequestMessage);
    }
}
